/**
 * @author 陈泰来
 * @version V1.0
 * @Project echo-java-base
 * @Title 消费者
 * @Description
 * @Package concurrent.blockingQueue.bqtest3
 * @date 2021/3/22 4:45 下午
 * @Copyright:学如逆水行舟，不进则退 .
 */
package concurrent.blockingQueue.bqtest3;

public class Consumer implements Runnable {

    BQTestQueue3<String> bqTestQueue3;

    public Consumer(BQTestQueue3<String> bqTestQueue3) {
        this.bqTestQueue3 = bqTestQueue3;
    }

    @Override
    public void run() {
        try {
            for (;;){
                bqTestQueue3.take();
            }


        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}
